package com.wnxy.a_work;

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

// 1、简单模式、工作队列模式
@Component
public class WorkProducer {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendMsg(){
        // 参数1：交换机（如果是简单模式，用空字符串表示）
        // 参数2：路由key（如果是简单模式，这里指定的是队列名称）
        // 参数3：消息内容
        rabbitTemplate.convertAndSend("","queue-simple-hello","Hello,Rabbit!");
    }

    // 程序中创建队列
    @Bean
    public Queue createQueue(){
        return QueueBuilder.durable("queue-simple-hello").build();
    }
}
